package com.gaofans.nrpc.common.processor;

/**
 * @author GaoFans
 */
public interface Sink<T> {

    /**
     * 写入下一个
     * @param t
     * @return
     */
    Sink<T> next(T t);

    /**
     * 写入完成
     */
    void complete();

    /**
     * 出错
     * @param throwable
     */
    void error(Throwable throwable);



}
